package com.citi.kafka.serializer.json;

import com.alibaba.fastjson.JSON;
import org.apache.kafka.common.serialization.Deserializer;

import java.util.Map;

public class PersonJsonDeserializer implements Deserializer<Person> {
    public void configure(Map<String, ?> map, boolean b) {

    }

    public Person deserialize(String topic, byte[] bytes) {
        return JSON.parseObject(bytes, Person.class);
    }

    public void close() {

    }
}
